package com.shujia.flink.transform;

import org.apache.flink.api.common.functions.MapFunction;

public class NameMapFunction implements MapFunction<String, String> {
    @Override
    public String map(String value) throws Exception {
        return value.split(",")[1];
    }
}
